package com.hoveagle.kafka.consumer;

import com.hoveagle.kafka.handler.MessageHandler;

/**
 * A message kafka factory is used to creating message kafka instance
 * @author hoveagle
 */
public final class MessageConsumerFactory {

    private MessageConsumerFactory(){
    }

    public static MessageConsumer newInstance(KafkaConfig consumerConfig, MessageHandler messageHandler){
        return new BusinessConsumer<>(consumerConfig,messageHandler);
    }
}
